//package com.captjack.simple.application.kafka;
//
//import kafka.javaapi.producer.Producer;
//import kafka.producer.KeyedMessage;
//import kafka.producer.ProducerConfig;
//
//import java.util.Properties;
//import java.util.UUID;
//
///**
// * @author Administrator
// */
//public class TestProducer {
//
//    public static void main(String[] args) {
//        try {
//            Properties props = new Properties();
//            props.put("metadata.broker.list", "192.168.110.197:9091,192.168.110.197:9092,192.168.110.197:9093");
//            props.put("serializer.class", "kafka.serializer.StringEncoder");
//            props.put("request.required.acks", "0");
//            props.put("message.send.max.retries", "3");
//            props.put("rebalance.backoff.ms", "5");
//            props.put("zookeeper.session.timeout.ms", "10");
//            props.put("key.serializer.class", "kafka.serializer.StringEncoder");
//            props.put("auto.create.topics.enable", "true");
//            // 推送
//            Producer<String, String> producer = new Producer<String, String>(new ProducerConfig(props));
//            while (true) {
//                producer.send(new KeyedMessage<String, String>(Constant.TOPIC, UUID.randomUUID().toString(), "currentTime: " + System.currentTimeMillis()));
//                System.out.println("send success!");
//                Thread.sleep(2000L);
//            }
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
//    }
//
//}
